const fetch = require('node-fetch');

async function fetchStreamData() {
    try {
        // 发起请求
        const response = await fetch('http://localhost:3000/stream');
        if (!response.ok) {
            throw new Error(`HTTP error! status: ${response.status}`);
        }

        // 直接使用 Node.js 的 Readable 流
        response.body.on('data', (chunk) => {
            // 将数据块输出到终端
            process.stdout.write(chunk.toString());
        });

        response.body.on('end', () => {
            console.log('\nStream finished.');
        });

        response.body.on('error', (error) => {
            console.error('Stream error:', error);
        });

    } catch (error) {
        console.error('Error:', error);
    }
}

// 调用函数获取流式数据
fetchStreamData();